//package com.ruoyi.common.config;
//
////import com.ruoyi.common.kafka.KafkaConsumerListener;
////import com.ruoyi.common.kafka.KafkaListenerJob;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.kafka.clients.consumer.ConsumerConfig;
//import org.apache.kafka.clients.consumer.KafkaConsumer;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//import java.util.Collections;
//import java.util.Properties;
//
//@Configuration
//@Slf4j
//public class KafkaConfig {
//    @Value("${spring.kafka.bootstrap-servers}")
//    public String kafka_server;
//
//    @Value("${spring.kafka.consumer.key-deserializer}")
//    public String kafka_consumer_key;
//
//    @Value("${spring.kafka.consumer.value-deserializer}")
//    public String kafka_consumer_value;
//
//    @Value("${spring.kafka.consumer.enable-auto-commit}")
//    public String kafka_auto_config;
//
//    @Value("${spring.kafka.consumer.auto-commit-interval}")
//    public String kafka_commmit_interval;
//
//    @Value("${spring.kafka.consumer.group-id}")
//    public String kafka_group_id;
//
//    @Value("${spring.kafka.consumer.topic-name}")
//    public String kafka_topic_name;
//
//    @Autowired
//    private KafkaConsumerListener kafkaConsumerListener;
//
//    public static KafkaConsumer<String, String> kafkaConsumer;
//
//    @Bean
//    public void loadKafkaConfig() {
//        Properties p = new Properties();
//        p.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafka_server);
//        p.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, kafka_consumer_key);
//        p.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, kafka_consumer_value);
//        p.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, kafka_auto_config);
//        p.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, kafka_commmit_interval);
//        p.put(ConsumerConfig.GROUP_ID_CONFIG, kafka_group_id);
//
//        kafkaConsumer = new KafkaConsumer<String, String>(p);
//        kafkaConsumer.subscribe(Collections.singletonList(kafka_topic_name));// 订阅消息
//        log.info("消息订阅成功！kafka配置：" + p.toString());
//        //启动消息监听线程
//        KafkaListenerJob kafkaListenerJob = new KafkaListenerJob(kafkaConsumerListener);
//        Thread t = new Thread(kafkaListenerJob);
//        t.start();
//    }
//}
